package com.flitsneak.kafka.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * @author flitsneak
 * @email flitsneak@gmail.com
 * @date 2022/8/10 14:58
 * @description
 */
@Slf4j
@Configuration
public class KafkaConsumer {
    @KafkaListener(topics = "topic1")
    public void consumeTopic(String msg) {
        log.info("kafka监听到消息：{}",msg);
    }
}
